package cn.kuporo.seckill.common.constants;

/**
 * @author: kuporo
 * @since: 2025/7/17
 * @description: MQ常量
 */
public interface MQConstants {

    /**
     * 消息的key
     */
    String MSG_KEY = "message";
    

    /**
     * 活动消费分组
     */
    String EVENT_ACTIVITY_CONSUMER_GROUP = "event_activity_consumer_group";
    /**
     * 活动事件消息topic
     */
    String TOPIC_EVENT_ROCKETMQ_ACTIVITY = "topic_event_rocketmq_activity";
    

    /**
     * 商品事件消息topic
     */
    String TOPIC_EVENT_ROCKETMQ_GOODS = "topic_event_rocketmq_goods";
    /**
     * 商品消费分组
     */
    String EVENT_GOODS_CONSUMER_GROUP = "event_goods_consumer_group";


    /**
     * 订单事件消息topic
     */
    String TOPIC_EVENT_ROCKETMQ_ORDER = "topic_event_rocketmq_order";
    /**
     * 订单消费分组
     */
    String EVENT_ORDER_CONSUMER_GROUP = "event_order_consumer_group";
    
    

    // ====================事务消息====================

    /**
     * 事务消息主题
     */
    String TOPIC_TX_MSG = "topic_tx_msg";

    /**
     * 异常消息主题
     */
    String TOPIC_ERROR_MSG = "topic_error_msg";

    /**
     * 商品消费分组
     */
    String TX_GOODS_CONSUMER_GROUP = "tx_goods_condumer_group";

    /**
     * 订单消费分组
     */
    String TX_ORDER_CONSUMER_GROUP = "tx_order_consumer_group";
    
    
    
    // ====================异步下单====================
    
    /**
     * 提交订单任务的消息主题
     */
    String TOPIC_ORDER_MSG = "topic_order_msg";

    /**
     * 提交订单分组
     */
    String SUBMIT_ORDER_CONSUMER_GROUP = "submit_order_consumer_group";
    
    
    
    // ====================库存编排====================
    String EVENT_STOCK_CONSUMER_GROUP = "event_stock_consumer_group";
    String TOPIC_EVENT_ROCKETMQ_STOCK = "topic_event_rocketmq_stock";
    String TOPIC_BUCKET_TX_MSG = "topic_bucket_tx_msg";
    String TX_STOCK_CONSUMER_GROUP = "tx_stock_condumer_group";

}
